package com.unism.uniMeterage.meterage.stream.version1_1.listener;

import com.unism.uniMeterage.meterage.stream.MessageEvent;
import com.unism.uniMeterage.meterage.stream.MessageListener;
/**
 * @author liuc
 * 监听completed事件的句柄函数
 */
public class CompletedListener implements MessageListener {
    @Override
    public void doMessage(MessageEvent e) {
        if(e.getStatus() == MessageEvent.MessageStatus.COMPLETED){
            System.out.println("时间:"+System.currentTimeMillis()+" 监听到completed事件,内容为:"+e.getSource());
        }
    }
}